package com.codejiwei.flink.udfs;

import org.apache.flink.table.functions.ScalarFunction;

/**
 * @author jiwei
 * @description 字符串转数组
 * @date 2023/6/21 9:50
 */
public class UDFStringToArray extends ScalarFunction {

    public String[] eval(String str, String separator) {
        String[] split = str.split(separator);
        return split;
    }
    
}
